package com.hex.ds.hdtp.core.inf.data.contrast.repository;

import com.hex.ds.hdtp.core.inf.common.page.Page;
import com.hex.ds.hdtp.core.inf.common.repository.IBasicRepository;
import com.hex.ds.hdtp.core.inf.data.contrast.po.CrossDbContrastRunLogPo;
import com.hex.ds.hdtp.core.inf.data.contrast.po.CrossDbContrastTaskPo;

import java.util.List;

/**
 * @Package: com.hex.ds.hdtp.core.inf.data.contrast.repository
 * @ClassName ICrossDbContrastTaskRepository
 * @Description: 跨库对比任务-数据服务接口
 * @Author: wz.li
 * @Date 2023/7/24 16:23
 * @Version v2.0.2
 **/
public interface ICrossDbContrastTaskRepository extends IBasicRepository<CrossDbContrastTaskPo> {

    /*
     * @Method: queryListByPage <br>
     * @Param: [crossDbContrastTaskPo, toPage] <br>
     * @Return: com.hex.ds.hdtp.core.inf.common.page.Page<com.hex.ds.hdtp.core.inf.data.contrast.po.CrossDbContrastTaskPo> <br>
     * @Description：分页查询<br>
     * @Author： wz.li<br>
     * @Date： 2023/7/24 18:17 <br>
     * @Version： V2.0.2<br>
     */
    Page<CrossDbContrastTaskPo> queryListByPage(CrossDbContrastTaskPo crossDbContrastTaskPo, Page toPage);

    /*
     * @Method: queryList <br>
     * @Param: [crossDbContrastTaskPo] <br>
     * @Return: java.util.List<com.hex.ds.hdtp.core.inf.data.contrast.po.CrossDbContrastTaskPo> <br>
     * @Description：不分页查询<br>
     * @Author： wz.li<br>
     * @Date： 2023/7/24 18:17 <br>
     * @Version： V2.0.2<br>
     */
    List<CrossDbContrastTaskPo> queryList(CrossDbContrastTaskPo crossDbContrastTaskPo);

    String addWithBackPkId(CrossDbContrastTaskPo crossDbContrastTaskPo);

    Integer updateStatusById(String pkId, String startTime);

    Integer updateEndStatusById(String pkId);

    Integer updateCountById(CrossDbContrastRunLogPo recentByTask);

    /**
     * 停止比对任务
     *
     * @param pkId
     * @param status
     * @return
     */
    Integer modifyTaskFinish(String pkId, String status);
}
